/**
 * Project Name:springBoot-serviceImpl
 * File Name:ConsumerPublishSubscribeServiceImpl.java
 * Package Name:com.libra.rabbitmq.publishSubscribe.serviceImp
 * Date:2018年8月20日下午7:20:11
 * Copyright (c) 2018, wangzhch All Rights Reserved.
 *
*/

package com.libra.rabbitmq.publishSubscribe.serviceImp;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import com.libra.model.mq.Teacher;
import com.libra.rabbitmq.config.QueueConstants;

/**
 * ClassName:ConsumerPublishSubscribeServiceImpl <br/>
 * Function: TODO ADD FUNCTION. <br/>
 * Reason:	 TODO ADD REASON. <br/>
 * Date:     2018年8月20日 下午7:20:11 <br/>
 * @author   wangzhch
 * @version  
 * @since    JDK 1.8
 * @see 	 
 */
@Component
public class ConsumerPublishSubscribeServiceImpl {
	Logger logger = LoggerFactory.getLogger(ConsumerPublishSubscribeServiceImpl.class);
	
	@RabbitListener(queues = QueueConstants.PS_QUEUE_A)
	public void psXiaofeiA(Teacher teacher) {
		logger.info("发布订阅模式进行A队列消费：{}",teacher);
	}
	
	@RabbitListener(queues = QueueConstants.PS_QUEUE_B)
	public void psXiaofeiB(Teacher teacher) {
		logger.info("发布订阅模式进行B队列消费：{}",teacher);
	}
	
	@RabbitListener(queues = QueueConstants.PS_QUEUE_C)
	public void psXiaofeiC(Teacher teacher) {
		logger.info("发布订阅模式进行C队列消费：{}",teacher);
	}
}

